C:/Projekte/RAIS/common/RADEVClasses/RADEVTable.cs

Go to the documentation of this file.

using System;
using System.Collections.Generic;
using System.Text;
using System.Data.OleDb;
using System.Data.Common;
using System.Data;
using System.Data.SqlClient;
using System.Configuration;

namespace RAIS.Common.RADEVClasses
{
    public abstract class RADEVTable
    {
        #region Fileds
        protected static string connectionString = "Provider=Microsoft.Jet.OLEDB.4.0;Data Source=D:\\RADEVData.mdb;";

        protected string _IAEAEventID = "";
        #endregion
        #region Properties



        public string IAEAEventID { get { return _IAEAEventID; } }
        #endregion
        #region Public methods






        public static RADEVTable CreateTable(string provderName, string tableName)
        {
            ConnectionStringSettings connectionSet =
                    ConfigurationManager.ConnectionStrings["RAISConnectionString"];
            connectionString = connectionSet.ConnectionString;

            RADEVTable instance;
            using (DbConnection connection = GetConnection(provderName))
            {
                using (DbCommand command = GetCommand(tableName, connection, out instance))
                {
                    using (DbDataReader reader = command.ExecuteReader())
                    {
                        while (reader.Read())
                        {
                            instance.AddNewRow(reader);
                        }
                    }
                }
            }
            return instance;
        }
        public abstract List<RADEVTable> GetData();
        public abstract string GetSourceName();
        public abstract bool IsValid(RADEVCriterias criterias);
        public object GetDataList(RADEVCriterias criterias)
        {
            List<RADEVTable> ret = new List<RADEVTable>();
            foreach (RADEVTable value in GetData())
            {
                if (value.IsValid(criterias))
                    ret.Add(value);
            }
            return ret;
        }
        #endregion
        #region Private methods
        private static DbCommand GetCommand(string tableName, DbConnection connection,out RADEVTable instance)
        { 
            DbCommand command;

            switch (tableName)
            {
                case "EventMaster":
                    instance = EventMaster.CreateInstatce();
                    break;
                case "EventWorkPublicDosimetry":
                    instance = EventWorkPublicDosimetry.CreateInstatce();
                    break;
                case "RadiationGenerator":
                    instance = RadiationGenerator.CreateInstatce();
                    break;
                case "RadiationDevice":
                    instance = RadiationDevice.CreateInstatce();
                    break;
                case "RadiationSource":
                    instance = RadiationSource.CreateInstatce();
                    break;
                case "EventWorkerPublicType":
                    instance = EventWorkerPublicType.CreateInstatce();
                    break;
                case "EventWorkerPublicCauses":
                    instance = EventWorkerPublicCauses.CreateInstatce();
                    break;
                default:
                    throw new Exception("Don't support this report");
            }

            if (connection is OleDbConnection)
                command = new OleDbCommand(instance.GetCommandString(), connection as OleDbConnection);
            else if(connection is SqlConnection)
                command = new SqlCommand(instance.GetCommandString(), connection as SqlConnection);
            else
                throw  new Exception("Don't support this provider");


            return command;
        }
        private static DbConnection GetConnection(string provderName)
        {
            DbConnection con;
            if(provderName=="access")
                con = new OleDbConnection(connectionString);
            else if (provderName=="sql")
                con = new SqlConnection(connectionString);
            else
                throw new Exception("Don't support this provider");
            con.Open();
            return con;
        }
        protected abstract string GetCommandString();
        protected abstract void AddNewRow(IDataReader reader);
        protected RADEVTable(string iAEAEventID)
        {
            _IAEAEventID = iAEAEventID;
        }
        protected RADEVTable() { }
        #endregion
    }
}